package handlers

import "github.com/ThreeDotsLabs/watermill/message"

// BatchHandler 所有类型的处理器都需实现该接口
type BatchHandler interface {
	UnmarshalAndCollect(msg *message.Message) error
	Handle() error
}

// BatchHandlerConstructor 是构造函数类型
type BatchHandlerConstructor func() BatchHandler
